var redis = require("redis")

config_param = {
    host: "10.10.117.81",
    port: 6379,
    password: "Surfilter@1218",
    db: 0
}

const client = redis.createClient(config_param)

const testKey = "test-key-001"

client.lpush(testKey, ["1", "2", "3"])


function myFunc(){
    client.rpop(testKey, function(err, resp) {
        if (err) throw err;
        var site_url = resp;
        console.log("接收数据：", site_url);
    })
}

// 每1s执行一次，从redis队列获取数据（可以设置每5s执行一次，从redis队列获取数据，获取成功则继续执行）
setInterval(myFunc, 1000);


// client.quit();

// client.rpop(testKey, function(err, resp) {
//     if (err) throw err;
//     console.log("接收数据：", resp);
// })

// client.brpop(testKey, 3, function(err, resp) {
//     if (err) throw err;
//     console.log("接收数据：", resp);
// })

